profiler

迅速排查后台慢的原因。

// usage:
// import "gitlab.p1staff.com/antispam/tantan-backend-moderation/tools/profile"
// defer longTimeWarning(time.Now())
func LongTimeWarning(invocation time.Time) {
	elapsed := time.Since(invocation)
	if elapsed < time.Second {
		return
	}
	programCounter, _, _, _ := runtime.Caller(1)
	fnName := runtime.FuncForPC(programCounter).Name()
	names := strings.Split(fnName, "tantan-backend-moderation/")
	name := names[len(names)-1]
	slog.Warning("longTimeFunction found: %s, duration: %s", name, elapsed)
}

通用的队列实现

将取任务动作抽象出来，把db状态映射到内存中。

package queue

type IQueueProducer interface {
	Preload() ([]Job, error)
}

type IQueueConsumer interface {
	GetOriginal(map[string]interface{}) ([]Job, error)
	Get(*Queue, map[string]interface{}) ([]Job, error)
	Validate([]Job, map[string]interface{}) ([]Job, error)
}